package com.ubox.mqtt_upush.mqttbroker;

import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.BrokerPlugin;

public class SessionPlugin implements BrokerPlugin{
	public  SessionFilter  sessionFilter;
	@Override
	public Broker installPlugin(Broker broker) throws Exception {
		sessionFilter=new SessionFilter(broker);
		return sessionFilter;
	}

}
